﻿using System;
using System.Threading;
using ConsoleApp.Infrastructure.Attributes;
using ConsoleApp.Infrastructure.Rmq;
using ConsoleApp.Infrastructure.TaskFramework;
using ConsoleApp.Util;

namespace ConsoleApp.Job.TaskJob.队列消费
{
    //[TaskInterceptor("Rmq测试消费任务", TaskLevel.One)]
    //public class Rmq测试消费任务 : TaskBase
    //{
    //    public override void Execute()
    //    {
    //        Thread.Sleep(15000);
    //        //ConsoleHelper.WriteInfoLine($"Rmq信息{RmqQueueManager.GetNodesDetail()}");
    //        $"队列中的消息总数{RmqQueueManager.GetQueueCount(RmqQueueManager.QueueName.测试)}".WriteInfoLine();
    //        $"Rmq测试任务开始消费".WriteSuccessLine();
    //        while (true)
    //        {
    //            new Rmq测试任务消费_RMQ(RmqQueueManager.QueueName.测试).HandleOneMessage();
    //        }
    //    }
    //}

    //public class Rmq测试任务消费_RMQ : OneConsumerWorkerBase<string>
    //{
    //    public Rmq测试任务消费_RMQ(string queueName)
    //    {
    //        Console.Title = queueName;
    //        QueueName = queueName;
    //    }

    //    public void Handler(string message)
    //    {
    //        HandleComingMessage(message);
    //    }

    //    protected override bool HandleComingMessage(string message)
    //    {
    //        try
    //        {
    //            $"消费成功{message}".WriteSuccessLine();
    //        }
    //        catch (Exception ex)
    //        {
    //            ex.ToString().WriteErrorLine();
    //        }
    //        return true;
    //    }
    //}
}
